package com.atguigu.gulimall.order.test;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.connection.CorrelationData;

import java.nio.channels.Channel;

@RabbitListener(queues = {"direct.queue1"})
public class ReceiveMsg {
    //channal可以来是否接收消息
    @RabbitHandler
    public void simple(Message message, String str, CorrelationData correlationData, Channel channel){

    }
}
